from apscheduler.schedulers.blocking import BlockingScheduler
from apscheduler.executors.pool import ProcessPoolExecutor

# 1.定义执行器
executors = {
    # default表示执行定时任务时,使用进程的方式
    # 3表示在同一个时刻,最多只有3个进程同时执行
    'default': ProcessPoolExecutor(3)
}
# 2.使用上面的执行器,创建调度管理对象,使用单独运行的方式
scheduler = BlockingScheduler(executors=executors)
# 3.定义定时任务函数
def print_test():
    print('定时任务执行成功')
# 4.添加任务,使用date指定在某个时间执行
scheduler.add_job(print_test, 'date', run_date = '2019-08-19 13:49:14')

if __name__ == '__main__':
    # 5.启动调度器管理
    scheduler.start()